//package cn.iocoder.yudao.module.pi.mq.mq.producer;
//
//import cn.iocoder.yudao.module.demo.mq.message.DemoInfoSendMessage;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.core.RocketMQTemplate;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//
///**
// * Demo demo相关消息的 Producer
// *
// * @author 徐煜东
// * @since 2025/6/1 16:35
// */
//@Slf4j
//@Component
//public class DemoInfoSendProducer {
//    @Resource
//    private RocketMQTemplate rocketMQTemplate; // 重点：注入 RocketMQTemplate 对象
//
//    public void sendProductInfoMessage(DemoInfoSendMessage message) {
//        rocketMQTemplate.syncSend(DemoInfoSendMessage.TOPIC, message); // 重点：使用 RocketMQTemplate 同步发送消息
//    }
//}
